package cn.iotab.iotkit.transport.api.common.message.codec;

import cn.iotab.iotkit.transport.api.common.message.JsonQueueMsg;
import cn.iotab.iotkit.transport.api.common.message.TransportMsg;

public class QueueMessageFactory {

    private static final JsonMsgEncoder msgEncoder = new JsonMsgEncoder();

    public static <T extends TransportMsg> JsonQueueMsg<T> createQueueMessage(String key, T msg) {
        return msgEncoder.encode(key, msg);
    }


}
